/**
 * @desc 数据库边接池技术，用于操作数据基础操作
 * @data 2018-05-21 
 */
var mysql = require("mysql");
const util = require('util');
/**
 * 数据库连接操作，此处使用连接池
 */
var pool = mysql.createPool({
    host : '192.168.1.180',
    user : 'examsys',
    password:'examsys',
    port:'3306',
    database:'examsys'
});

//声明相应的模块
var curd = {};
/**
 * 声明方法 ： query 用于操作相应的sql语句 
 * @param sql 语句 
 * @param param 相应的sql语句参数
 * @param callback 相应的回调函数
 */
curd.query = function (sql,param,callback){
    //从池里获取相应的连接数
    pool.getConnection(function(err,connection) {  
        if(err) {  
            throw err;
            console.log("建立连接失败");  
        }else{  
            console.log("建立连接成功");  
            connection.query(sql,param,function(err,rows) {
                callback(rows);
            });  
        }  
        //释放相应的连接加到池中
        pool.releaseConnection(connection);
    }) ;
}

module.exports = curd;
